package cn.me.alphamq.broker.event.model.broker;

import cn.me.alphamq.common.entity.req.PushTxMsgReq;
import cn.me.alphamq.common.event.model.Event;

/**
 * 推送事务消息的事件
 *
 * @author f
 */
public class PushTxMsgEvent extends Event {

    private final PushTxMsgReq pushTxMsgReq;

    public PushTxMsgEvent(PushTxMsgReq pushTxMsgReq) {
        this.pushTxMsgReq = pushTxMsgReq;
    }

    public PushTxMsgReq getPushTxMsgReq() {
        return pushTxMsgReq;
    }
}
